package com.jeffse.light.stream.core.data.collector;

import java.io.Serializable;

public interface Collector<T> extends Serializable {
    void collect(T record) throws Exception;
}
